package cn.acrdpm.service;

import cn.acrdpm.entity.MsgLog;
import cn.acrdpm.entity.MsgLogWithBLOBs;

import java.util.List;

public interface MsgLogService {

    /**
     * 更新 消息状态
     * @param msgId 消息id
     * @param status 状态
     */
    void updateStatus(String msgId, Integer status);

    /**
     * 根据id 查询消息
     * @param msgId 消息 id
     * @return
     */
    MsgLog selectByMsgId(String msgId);

    /**
     * 查询所有重试的消息
     * @return
     */
    List<MsgLogWithBLOBs> selectTimeoutMsg();

    void updateTryCount(String msgId, Integer tryCount);
}
